package streamAPI.project.activityselectname;

import org.apache.flink.streaming.api.datastream.DataStream;
import util.FlinkUtils;

/**
 * 读取kafka中的数据 并 解释其中的一个数据 从mysql中读取
 *
 * 数据准备 和 kafka数据
 * /project/QueryActivityInfoProject.sql
 *
 * @author yue.cao
 * @since 10-19-2020
 */
public class QueryActivityInfoProject {

	public static void main(String[] args) throws Exception {
		DataStream<String> dataStream = FlinkUtils.createCommonKafkaStream();
		dataStream.map(new LineToActivityInfo()).print();
		FlinkUtils.execute();
	}
}
